package cn.xyw.solr;

import cn.xyw.pojo.Item;
import org.apache.solr.client.solrj.SolrServer;
import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.common.SolrInputDocument;
import org.junit.Test;

import java.io.IOException;

/**
 * @author Evan
 * @Title: SolrIndexCreate
 * @ProjectName solr
 * @Description: TODO
 * @date 2018/7/520:48
 */
public class SolrIndexCreate {
    /**
    　　* @Description: 以document形式添加或修改数据
    　　* @param []
    　　* @return void
    　　* @author Evan
    　　* @date 2018/7/5 21:00
    　　*/
    @Test
    public void testCreateIndex() throws IOException, SolrServerException {
        // 连接服务器
        SolrServer server = new HttpSolrServer("http://localhost:8080/solr/core2");

        // 创建solr的输入document
        SolrInputDocument document = new SolrInputDocument();

        // 添加字段
        document.addField("id","123456");
        document.addField("title","奔驰Gxxxx");
        document.addField("price",83000000);

        // 添加document到server
        server.add(document);

        // 提交请求(如果id存在则创建数据)
        server.commit();

    }

    /**
     　　* @Description: 以JavaBean形式添加或修改数据
     　　* @param []
     　　* @return void
     　　* @author Evan
     　　* @date 2018/7/5 21:00
     　　*/
    @Test
    public void testCreateIndexBean() throws IOException, SolrServerException {
        // 连接服务器
        SolrServer server = new HttpSolrServer("http://localhost:8080/solr/core2");

        // 创建一个实体类对象
        Item item = new Item();
        item.setId("121212");
        item.setTitle("兰博基尼好车");
        item.setPrice(12000000);

        // 添加document到server
        server.addBean(item);

        // 提交请求(如果id存在则创建数据)
        server.commit();

    }


}
